package com.handler;

import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessagingException;

/**
 * @Author: chihaojie
 * @Date: 2019/5/30 16:40
 * @Version 1.0
 * @Note
 */
public class MqttMessageHandler implements MessageHandler {

    @Override
    public void handleMessage(Message<?> message) throws MessagingException {
        System.out.println(message.getPayload());
    }
}
